Code available <a target="_blank" href="https://github.com/confluentinc/kafka-connect-storage-common/blob/master/core/src/main/java/io/confluent/connect/storage/tools/SchemaSourceConnector.java">here</a>